c965c5946911063352804e591955e8d1927aed6e,src/main/java/com/continuuity/data/operation/ttqueue/QueuePartitioner.java,HashPartitioner,shouldEmit,#QueueConsumer#number#number#,119

Before Change



    @Override
    public boolean shouldEmit(QueueConsumer consumer, long entryId, int hash) {
      return (hash % consumer.getGroupSize() == consumer.getInstanceId());
    }

    @Override

After Change



    @Override
    public boolean shouldEmit(QueueConsumer consumer, long entryId, int hash) {
      return (hash % consumer.getGroupSize() == consumer.getInstanceId() % consumer.getGroupSize());
    }

    @Override